const { Q } = require('@alyne/lib-q');

let q;

const messages = new Set();
function _addToMessages(message, prefix = '') {
  const messageId = prefix + JSON.stringify(message);
  messages.add(messageId);
}

const INSTANCE_NAME = 'test';
const sqsConfig = require('./sqsConfig');

const chismeId = 'lib-q-test';

const redisConfig = {
  url: 'redis://localhost:6379'
};

const chismeConfig = {
  chismeId,
  chismeHandlers: {
    doIt: () => {
      _addToMessages({}, chismeId);
    }
  }
};

const RPC = 'rpc';
const REPLIES = 'replies';

async function produceMessage() {
    q = new Q({
      redisConfig,
      chismeConfig,
      sqsConfig,
      instanceName: INSTANCE_NAME
    });

  await q.init();

  await q.task({
    queueName: RPC,
    type: RPC,
    body: {
      type: 'services',
      item: 'exampleService',
      method: 'processData',
      params: ['param1', 'param2']
    }
  });
  console.log('Task sent using q with region:', q.awsRegion);

};

produceMessage();

const { Consumer } = require('@alyne/sqs-consumer');
const { SQSClient } = require('@aws-sdk/client-sqs');

const sqsClient = new SQSClient({
  region: 'eu-west-1',
  endpoint: 'http://localhost:4566',
  credentials: {
    accessKeyId: 'test',
    secretAccessKey: 'test'
  }
});

const queueUrl = 'http://localhost:4566/000000000000/my-queue';

const app = Consumer.create({
  queueUrl,
  handleMessage: async (message) => {
    const body = JSON.parse(message.Body);
    console.log('Received message:', body);
  },
  sqs: sqsClient
});

app.on('error', (err) => {
  console.error('Error:', err.message);
});

app.on('processing_error', (err) => {
  console.error('Processing error:', err.message);
});

app.on('message_received', (message) => {
  console.log('Message received, ID:', message.MessageId);
});

app.on('message_processed', (message) => {
  console.log('Message processed, ID:', message.MessageId);
});

app.on('empty', () => {
  console.log('Queue is empty');
});

console.log('Queue URL:', queueUrl);
console.log('Starting SQS consumer on my-queue...');
app.start();